//1.导入mysql
const mysql = require('mysql')

//2.建立连接
const db = mysql.createPool({
  host:'127.0.0.1',//数据库的ip地址
  user:'root',//登录数据库的账号
  password:'123456',//mysql密码
  database:'xin'//数据库名
})

// 检查mysql模块是否正常工作
// db.query('select 1', (err, results) => {
//   if (err) return console.log(err.message);
//   console.log(results);
// })


//查
// const sqlStr = 'select * from sholl'

// db.query(sqlStr, (err,results) => {
//   if (err) return console.log(err.message);
//   console.log(results);
// })

//增
// const shMessage = {id : 3,name:'三班'}

// const sqlStr = 'insert into sholl (id,name) values(?,?)'

// //执行sql
// db.query(sqlStr, [shMessage.id,shMessage.name], (err, results) => {
//   if (err) return console.log(err.message)
//   if (results.affectedRows === 1) {
//     console.log('插入数据成功');
//   }
// })

// 增2
// let id = 3
// let name = '三班'
// const shMessage = {id : id,name:name}
// //定义sql语句
// const sqlStr = 'insert into lei set ?'
// db.query(sqlStr,shMessage, (err,results) => {
//   if (err) return console.log(err.message)
//   if (results.affectedRows ===1) {
//     console.log('插入数据成功');
//   }
// })

// 更新
// let id = 1
// let name = '一班'
// const shMessage = {id : id, name: name,id:id}
// //定义sql语句
// const sqlStr = 'update lei set id=?,name=? where id=?'
// //执行sql语句
// db.query(sqlStr,[shMessage.id,shMessage.name,shMessage.id], (err,result) => {
//   if (err) return console.log(err.message);
//   if (result.affectedRows ===1) {
//         console.log('数据更新成功');
//   }
// })

// 更新2
// let id = 1
// let name = '一班'
// const shMessage = {id : id, name: name,id:id}
// const sqlStr = 'update lei set ? where id=?'
// db.query(sqlStr,[shMessage,shMessage.id], (err,results) => {
//   if (err) return console.log(err.message)
//   if (results.affectedRows ===1) {
//     console.log('数据更新成功');
//   }
// })

//删除
// const sqlStr = 'delete from lei where id=?'
// db.query(sqlStr,3,(err,results) => {
//   if (err) return console.log(err.message)
//   if (results.affectedRows ===1) {
//     console.log('删除成功');
//   }
// })

//标记删除
const sqlStr = 'update lei set status=? where id=?'
db.query(sqlStr,[1,2],(err,results) => {
  if (err) return console.log(err.message)
  if (results.affectedRows ===1) {
    console.log('标记删除成功');
  }
})